Skip to content

Bench execute batch no more overhead hacks#3

Closed
ryoqun wants to merge 163 commits into
apfitzge:bench_execute_batchfrom
ryoqun:bench_execute_batch_no_more_overhead_hacks
Closed

Bench execute batch no more overhead hacks#3
ryoqun wants to merge 163 commits into
apfitzge:bench_execute_batchfrom
ryoqun:bench_execute_batch_no_more_overhead_hacks

Conversation

@ryoqun
Copy link
Copy Markdown

@ryoqun ryoqun commented Jan 12, 2024

@github-actions github-actions Bot added the stale label Jan 29, 2024
@github-actions github-actions Bot closed this Feb 5, 2024
apfitzge pushed a commit that referenced this pull request Oct 21, 2025
* Apply the retry code to the async pubsub client

Create a test server

```ts
import http from "http";

import { WebSocketServer } from "ws";

let attemptCount = 0;

const server = http.createServer();
const wss = new WebSocketServer({ noServer: true });

wss.on("connection", (ws) => {
  ws.send("Connection accepted.");
  ws.on("message", (msg) => console.log(`Received: ${msg}`));
});

server.on("upgrade", (req, socket, head) => {
  attemptCount += 1;

  if (attemptCount <= 4) {
    socket.write("HTTP/1.1 429 Too Many Requests\r\n\r\n");
    socket.destroy();
    console.log(`Rejected connection #${attemptCount} (429)`);
    return;
  }

  wss.handleUpgrade(req, socket, head, (ws) => {
    wss.emit("connection", ws, req);
    console.log("Connection accepted on attempt", attemptCount);
  });
});

server.listen(8080, () => {
  console.log("Server listening on port 8080");
});
```

Run `test_slot_subscription_async`:

```
Rejected connection #1 (429)
Rejected connection #2 (429)
Rejected connection #3 (429)
Rejected connection #4 (429)
Connection accepted on attempt 5
Received: {"id":1,"jsonrpc":"2.0","method":"slotSubscribe","params":[]}
```

* `s/async_with_retry/with_retry/`
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant